package com.ideal.lx_mss.common.entity;




import lombok.Data;

import java.util.Date;


/**
 * 
 * 
 * @author wangxiang1998
 * @email 2293672863@qq.com
 * @date 2023-12-20 10:32:04
 */

@Data
public class MssKafkaEntity{
	/**
	 * 主题
	 */

	private String topic;
	/**
	 * 分区信息
	 */
	private int partition;
	/**
	 * 偏移量
	 */
	private Long offset;
	/**
	 * 消息key
	 */
	private String mesKey;
	/**
	 * 消息值
	 */
	private String mesValue;






	public MssKafkaEntity() {

	}

	public MssKafkaEntity(String topic, Integer partition, Long offset, String mesKey, String mesValue) {
		this.topic = topic;
		this.partition = partition;
		this.offset = offset;
		this.mesKey = mesKey;
		this.mesValue = mesValue;

	}


}
